package com.atguigu.spring5_webflux.reactor8;

import java.util.Observable;

/**
 * 模拟 java.util.Observer
 * 测试观察者模式
 * oberver 观察者
 * observeralbe 被观察者
 */
public class ObserverDemo extends Observable {
    public static void main(String[] args) {
        ObserverDemo observer = new ObserverDemo();
        // 添加观察者
        observer.addObserver((o,arg) -> {
            System.out.println("我是观察者A，收到被观察者在变化后发出的通知，即将做出对应改变");
        });
        observer.addObserver((o,arg) -> {
            System.out.println("我是观察者B，收到被观察者在变化后发出的通知，即将做出对应改变");
        });
        observer.setChanged(); // 设定 被观察者 发生了变化
        observer.notifyObservers(); // 设定 被观察者 在发生了变化后，通知了观察者们

    }

}


